package demo.dag;

import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.dag.Transformation;
import org.apache.flink.streaming.api.operators.ChainingStrategy;
import org.apache.flink.streaming.api.operators.StreamOperatorFactory;

public class OneInputTransformationDemo<IN, OUT> extends  PhysicalTransformationDemo<OUT>{
    private final Transformation<IN> input;

    private final StreamOperatorFactory<OUT> operatorFactory;

    public OneInputTransformationDemo(
            Transformation<IN> input,
            String name,
            TypeInformation<OUT> outputType,
            StreamOperatorFactory<OUT> operatorFactory,
            int parallelism
            ) {
        super(name, outputType, parallelism);
        this.input = input;
        this.operatorFactory = operatorFactory;
    }

    @Override
    public void setChainingStrategy(ChainingStrategy strategy) {

    }
}
